<!DOCTYPE html>
<!-- saved from url=(0031)http://localhost:6060/pkg/RxGO/ -->
<html><head><meta http-equiv="Content-Type" content="text/html; charset=UTF-8">

<meta name="viewport" content="width=device-width, initial-scale=1">
<meta name="theme-color" content="#375EAB">

  <title>rxgo - Go Documentation Server</title>

<link type="text/css" rel="stylesheet" href="./rxgo - Go Documentation Server_files/style.css">

<script>window.initFuncs = [];</script>
<script src="./rxgo - Go Documentation Server_files/jquery.js.下载" defer=""></script>



<script>var goVersion = "go1.15.3";</script>
<script src="./rxgo - Go Documentation Server_files/godocs.js.下载" defer=""></script>
</head>
<body>

<div id="lowframe" style="position: fixed; bottom: 0; left: 0; height: 0; width: 100%; border-top: thin solid grey; background-color: white; overflow: auto;">
...
</div><!-- #lowframe -->

<div id="topbar" class="wide"><div class="container">
<div class="top-heading" id="heading-wide"><a href="http://localhost:6060/pkg/">Go Documentation Server</a></div>
<div class="top-heading" id="heading-narrow"><a href="http://localhost:6060/pkg/">GoDoc</a></div>
<a href="http://localhost:6060/pkg/RxGO/#" id="menu-button"><span id="menu-button-arrow">▽</span></a>
<form method="GET" action="http://localhost:6060/search">
<div id="menu" style="min-width: 60px;">

<span class="search-box"><input type="search" id="search" name="q" placeholder="Search" aria-label="Search" required=""><button type="submit"><span><!-- magnifying glass: --><svg width="24" height="24" viewBox="0 0 24 24"><title>submit search</title><path d="M15.5 14h-.79l-.28-.27C15.41 12.59 16 11.11 16 9.5 16 5.91 13.09 3 9.5 3S3 5.91 3 9.5 5.91 16 9.5 16c1.61 0 3.09-.59 4.23-1.57l.27.28v.79l5 4.99L20.49 19l-4.99-5zm-6 0C7.01 14 5 11.99 5 9.5S7.01 5 9.5 5 14 7.01 14 9.5 11.99 14 9.5 14z"></path><path d="M0 0h24v24H0z" fill="none"></path></svg></span></button></span>
</div>
</form>

</div></div>



<div id="page" class="wide" tabindex="-1" style="outline: 0px;">
<div class="container">


  <h1>
    Package rxgo
    <span class="text-muted"></span>
  </h1>







<div id="nav"></div>


<!--
	Copyright 2009 The Go Authors. All rights reserved.
	Use of this source code is governed by a BSD-style
	license that can be found in the LICENSE file.
-->
<!--
	Note: Static (i.e., not template-generated) href and id
	attributes start with "pkg-" to make it impossible for
	them to conflict with generated attributes (some of which
	correspond to Go identifiers).
-->

	<script>
	document.ANALYSIS_DATA = null;
	document.CALLGRAPH = null;
	</script>

	
		
		<div id="short-nav">
			<dl>
			<dd><code>import "RxGO"</code></dd>
			</dl>
			<dl>
			<dd><a href="http://localhost:6060/pkg/RxGO/#pkg-overview" class="overviewLink">Overview</a></dd>
			<dd><a href="http://localhost:6060/pkg/RxGO/#pkg-index" class="indexLink">Index</a></dd>
			
			
			</dl>
		</div>
		<!-- The package's Name is printed as title by the top-level template -->
		<div id="pkg-overview" class="toggleVisible">
			<div class="collapsed">
				<h2 class="toggleButton" title="Click to show Overview section">Overview ▹</h2>
			</div>
			<div class="expanded">
				<h2 class="toggleButton" title="Click to hide Overview section">Overview ▾</h2>
				
				
			</div>
		</div>

		<div id="pkg-index" class="toggleVisible">
		<div class="collapsed">
			<h2 class="toggleButton" title="Click to show Index section">Index ▹</h2>
		</div>
		<div class="expanded">
			<h2 class="toggleButton" title="Click to hide Index section">Index ▾</h2>

		<!-- Table of contents for API; must be named manual-nav to turn off auto nav. -->
			<div id="manual-nav">
			<dl>
			
			
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#All">func All(in chan interface{}, match MatchFunc) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#Amb">func Amb(in ...chan interface{}) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#Average">func Average(in chan interface{}) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#Buffer">func Buffer(in chan interface{}, count int, skip int) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#CombineLatest">func CombineLatest(chans ...chan interface{}) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#Concat">func Concat(chans ...chan interface{}) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#Contains">func Contains(in chan interface{}, match MatchFunc) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#Count">func Count(in chan interface{}) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#Debounce">func Debounce(in chan interface{}, duration time.Duration) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#DefaultIfEmpty">func DefaultIfEmpty(in chan interface{}, defaultVal interface{}) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#Delay">func Delay(in chan interface{}, delay time.Duration) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#Distinct">func Distinct(in chan interface{}) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#ElementAt">func ElementAt(in chan interface{}, nth int) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#Empty">func Empty() chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#Filter">func Filter(in &lt;-chan interface{}, filterFunc FilterFunc) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#First">func First(in chan interface{}) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#FlatMap">func FlatMap(in chan interface{}) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#From">func From(in []interface{}) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#GroupBy">func GroupBy(in chan interface{}, groupByFunc GroupByFunc) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#IgnoreElements">func IgnoreElements(in chan interface{}) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#Interval">func Interval(ctx context.Context, interval time.Duration, delay time.Duration, mapFunc MapFunc) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#IntervalRange">func IntervalRange(start int, count int, interval time.Duration, delay time.Duration) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#IsEmpty">func IsEmpty(in chan interface{}) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#Just">func Just(val interface{}) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#Last">func Last(in chan interface{}) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#Map">func Map(in &lt;-chan interface{}, mapFunc MapFunc) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#Max">func Max(in chan interface{}) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#Merge">func Merge(chans ...chan interface{}) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#Min">func Min(in chan interface{}) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#Range">func Range(start int, count int) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#Reduce">func Reduce(in &lt;-chan interface{}, reduceFunc ReduceFunc, initialVal interface{}) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#Repeat">func Repeat(in chan interface{}, repeat int, immediate bool) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#Sample">func Sample(in chan interface{}, interval time.Duration) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#SequenceEqual">func SequenceEqual(ins ...chan interface{}) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#Skip">func Skip(in chan interface{}, count int) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#SkipLast">func SkipLast(in chan interface{}, count int) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#SkipUntil">func SkipUntil(in chan interface{}, untilChan chan interface{}) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#SkipWhile">func SkipWhile(in chan interface{}, match MatchFunc) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#StartWith">func StartWith(in chan interface{}, vals ...interface{}) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#Subscribe">func Subscribe(in chan interface{}) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#Sum">func Sum(in chan interface{}) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#Switch">func Switch(in chan interface{}) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#Take">func Take(in chan interface{}, count int) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#TakeLast">func TakeLast(in chan interface{}, count int) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#TakeUntil">func TakeUntil(in chan interface{}, untilChan chan interface{}) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#TakeWhile">func TakeWhile(in chan interface{}, match MatchFunc) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#Throw">func Throw(err error) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#TimeInterval">func TimeInterval(in chan interface{}) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#Timeout">func Timeout(in chan interface{}, timeout time.Duration) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#Timer">func Timer(duration time.Duration) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#Timestamp">func Timestamp(in chan interface{}) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#Values">func Values(in chan interface{}) []interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#WindowWithCount">func WindowWithCount(in chan interface{}, count int) chan interface{}</a></dd>
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#Zip">func Zip(chans ...chan interface{}) chan interface{}</a></dd>
			
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#FilterFunc">type FilterFunc</a></dd>
				
				
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#GroupByFunc">type GroupByFunc</a></dd>
				
				
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#MapFunc">type MapFunc</a></dd>
				
				
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#MatchFunc">type MatchFunc</a></dd>
				
				
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#ReduceFunc">type ReduceFunc</a></dd>
				
				
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#TimeIntervalItem">type TimeIntervalItem</a></dd>
				
				
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#TimeoutError">type TimeoutError</a></dd>
				
				
					
					<dd>&nbsp; &nbsp; <a href="http://localhost:6060/pkg/RxGO/#TimeoutError.Error">func (timeoutError TimeoutError) Error() string</a></dd>
				
			
				
				<dd><a href="http://localhost:6060/pkg/RxGO/#TimestampItem">type TimestampItem</a></dd>
				
				
			
			
			</dl>
			</div><!-- #manual-nav -->

		

		
			<h3>Package files</h3>
			<p>
			<span style="font-size:90%">
			
				<a href="http://localhost:6060/src/RxGO/generator.go">generator.go</a>
			
				<a href="http://localhost:6060/src/RxGO/operator.go">operator.go</a>
			
			</span>
			</p>
		
		</div><!-- .expanded -->
		</div><!-- #pkg-index -->

		

		
		
		
			
			
			<h2 id="All">func <a href="http://localhost:6060/src/RxGO/operator.go?s=10724:10787#L683">All</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#All">¶</a>
				
				
			</h2>
			<pre>func All(in chan interface{}, match <a href="http://localhost:6060/pkg/RxGO/#MatchFunc">MatchFunc</a>) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="Amb">func <a href="http://localhost:6060/src/RxGO/operator.go?s=11224:11273#L721">Amb</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#Amb">¶</a>
				
				
			</h2>
			<pre>func Amb(in ...chan interface{}) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="Average">func <a href="http://localhost:6060/src/RxGO/operator.go?s=14748:14798#L954">Average</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#Average">¶</a>
				
				
			</h2>
			<pre>func Average(in chan interface{}) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="Buffer">func <a href="http://localhost:6060/src/RxGO/operator.go?s=2062:2132#L126">Buffer</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#Buffer">¶</a>
				
				
			</h2>
			<pre>func Buffer(in chan interface{}, count <a href="http://localhost:6060/pkg/builtin/#int">int</a>, skip <a href="http://localhost:6060/pkg/builtin/#int">int</a>) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="CombineLatest">func <a href="http://localhost:6060/src/RxGO/operator.go?s=6355:6417#L420">CombineLatest</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#CombineLatest">¶</a>
				
				
			</h2>
			<pre>func CombineLatest(chans ...chan interface{}) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="Concat">func <a href="http://localhost:6060/src/RxGO/operator.go?s=17447:17502#L1105">Concat</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#Concat">¶</a>
				
				
			</h2>
			<pre>func Concat(chans ...chan interface{}) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="Contains">func <a href="http://localhost:6060/src/RxGO/operator.go?s=10972:11040#L702">Contains</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#Contains">¶</a>
				
				
			</h2>
			<pre>func Contains(in chan interface{}, match <a href="http://localhost:6060/pkg/RxGO/#MatchFunc">MatchFunc</a>) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="Count">func <a href="http://localhost:6060/src/RxGO/operator.go?s=15087:15135#L975">Count</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#Count">¶</a>
				
				
			</h2>
			<pre>func Count(in chan interface{}) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="Debounce">func <a href="http://localhost:6060/src/RxGO/operator.go?s=3187:3262#L193">Debounce</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#Debounce">¶</a>
				
				
			</h2>
			<pre>func Debounce(in chan interface{}, duration <a href="http://localhost:6060/pkg/time/">time</a>.<a href="http://localhost:6060/pkg/time/#Duration">Duration</a>) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="DefaultIfEmpty">func <a href="http://localhost:6060/src/RxGO/operator.go?s=12035:12116#L768">DefaultIfEmpty</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#DefaultIfEmpty">¶</a>
				
				
			</h2>
			<pre>func DefaultIfEmpty(in chan interface{}, defaultVal interface{}) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="Delay">func <a href="http://localhost:6060/src/RxGO/operator.go?s=9193:9262#L577">Delay</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#Delay">¶</a>
				
				
			</h2>
			<pre>func Delay(in chan interface{}, delay <a href="http://localhost:6060/pkg/time/">time</a>.<a href="http://localhost:6060/pkg/time/#Duration">Duration</a>) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="Distinct">func <a href="http://localhost:6060/src/RxGO/operator.go?s=3538:3589#L217">Distinct</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#Distinct">¶</a>
				
				
			</h2>
			<pre>func Distinct(in chan interface{}) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="ElementAt">func <a href="http://localhost:6060/src/RxGO/operator.go?s=3805:3866#L237">ElementAt</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#ElementAt">¶</a>
				
				
			</h2>
			<pre>func ElementAt(in chan interface{}, nth <a href="http://localhost:6060/pkg/builtin/#int">int</a>) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="Empty">func <a href="http://localhost:6060/src/RxGO/generator.go?s=2134:2163#L116">Empty</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#Empty">¶</a>
				
				
			</h2>
			<pre>func Empty() chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="Filter">func <a href="http://localhost:6060/src/RxGO/operator.go?s=707:781#L37">Filter</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#Filter">¶</a>
				
				
			</h2>
			<pre>func Filter(in &lt;-chan interface{}, filterFunc <a href="http://localhost:6060/pkg/RxGO/#FilterFunc">FilterFunc</a>) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="First">func <a href="http://localhost:6060/src/RxGO/operator.go?s=4090:4138#L261">First</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#First">¶</a>
				
				
			</h2>
			<pre>func First(in chan interface{}) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="FlatMap">func <a href="http://localhost:6060/src/RxGO/operator.go?s=2549:2599#L155">FlatMap</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#FlatMap">¶</a>
				
				
			</h2>
			<pre>func FlatMap(in chan interface{}) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="From">func <a href="http://localhost:6060/src/RxGO/generator.go?s=45:89#L1">From</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#From">¶</a>
				
				
			</h2>
			<pre>func From(in []interface{}) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="GroupBy">func <a href="http://localhost:6060/src/RxGO/operator.go?s=2847:2922#L174">GroupBy</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#GroupBy">¶</a>
				
				
			</h2>
			<pre>func GroupBy(in chan interface{}, groupByFunc <a href="http://localhost:6060/pkg/RxGO/#GroupByFunc">GroupByFunc</a>) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="IgnoreElements">func <a href="http://localhost:6060/src/RxGO/operator.go?s=4421:4478#L284">IgnoreElements</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#IgnoreElements">¶</a>
				
				
			</h2>
			<pre>func IgnoreElements(in chan interface{}) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="Interval">func <a href="http://localhost:6060/src/RxGO/generator.go?s=351:464#L19">Interval</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#Interval">¶</a>
				
				
			</h2>
			<pre>func Interval(ctx <a href="http://localhost:6060/pkg/context/">context</a>.<a href="http://localhost:6060/pkg/context/#Context">Context</a>, interval <a href="http://localhost:6060/pkg/time/">time</a>.<a href="http://localhost:6060/pkg/time/#Duration">Duration</a>, delay <a href="http://localhost:6060/pkg/time/">time</a>.<a href="http://localhost:6060/pkg/time/#Duration">Duration</a>, mapFunc <a href="http://localhost:6060/pkg/RxGO/#MapFunc">MapFunc</a>) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="IntervalRange">func <a href="http://localhost:6060/src/RxGO/generator.go?s=918:1020#L55">IntervalRange</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#IntervalRange">¶</a>
				
				
			</h2>
			<pre>func IntervalRange(start <a href="http://localhost:6060/pkg/builtin/#int">int</a>, count <a href="http://localhost:6060/pkg/builtin/#int">int</a>, interval <a href="http://localhost:6060/pkg/time/">time</a>.<a href="http://localhost:6060/pkg/time/#Duration">Duration</a>, delay <a href="http://localhost:6060/pkg/time/">time</a>.<a href="http://localhost:6060/pkg/time/#Duration">Duration</a>) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="IsEmpty">func <a href="http://localhost:6060/src/RxGO/operator.go?s=17669:17719#L1121">IsEmpty</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#IsEmpty">¶</a>
				
				
			</h2>
			<pre>func IsEmpty(in chan interface{}) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="Just">func <a href="http://localhost:6060/src/RxGO/generator.go?s=2052:2095#L112">Just</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#Just">¶</a>
				
				
			</h2>
			<pre>func Just(val interface{}) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="Last">func <a href="http://localhost:6060/src/RxGO/operator.go?s=4169:4216#L265">Last</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#Last">¶</a>
				
				
			</h2>
			<pre>func Last(in chan interface{}) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="Map">func <a href="http://localhost:6060/src/RxGO/operator.go?s=118:183#L3">Map</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#Map">¶</a>
				
				
			</h2>
			<pre>func Map(in &lt;-chan interface{}, mapFunc <a href="http://localhost:6060/pkg/RxGO/#MapFunc">MapFunc</a>) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="Max">func <a href="http://localhost:6060/src/RxGO/operator.go?s=16361:16407#L1049">Max</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#Max">¶</a>
				
				
			</h2>
			<pre>func Max(in chan interface{}) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="Merge">func <a href="http://localhost:6060/src/RxGO/operator.go?s=941:995#L52">Merge</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#Merge">¶</a>
				
				
			</h2>
			<pre>func Merge(chans ...chan interface{}) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="Min">func <a href="http://localhost:6060/src/RxGO/operator.go?s=15290:15336#L993">Min</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#Min">¶</a>
				
				
			</h2>
			<pre>func Min(in chan interface{}) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="Range">func <a href="http://localhost:6060/src/RxGO/generator.go?s=1329:1378#L69">Range</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#Range">¶</a>
				
				
			</h2>
			<pre>func Range(start <a href="http://localhost:6060/pkg/builtin/#int">int</a>, count <a href="http://localhost:6060/pkg/builtin/#int">int</a>) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="Reduce">func <a href="http://localhost:6060/src/RxGO/operator.go?s=382:480#L18">Reduce</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#Reduce">¶</a>
				
				
			</h2>
			<pre>func Reduce(in &lt;-chan interface{}, reduceFunc <a href="http://localhost:6060/pkg/RxGO/#ReduceFunc">ReduceFunc</a>, initialVal interface{}) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="Repeat">func <a href="http://localhost:6060/src/RxGO/generator.go?s=1630:1707#L86">Repeat</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#Repeat">¶</a>
				
				
			</h2>
			<pre>func Repeat(in chan interface{}, repeat <a href="http://localhost:6060/pkg/builtin/#int">int</a>, immediate <a href="http://localhost:6060/pkg/builtin/#bool">bool</a>) chan interface{}</pre>
			<p>
*
</p>
<pre> * @immediate:
	- true: in(1-&gt;2-&gt;3), out (1-&gt;1-&gt;2-&gt;2-&gt;3-&gt;3)
	- false: in(1-&gt;2-&gt;3), out (1-&gt;2-&gt;3-&gt;1-&gt;2-&gt;3)
</pre>

			
			

		
			
			
			<h2 id="Sample">func <a href="http://localhost:6060/src/RxGO/operator.go?s=4605:4678#L298">Sample</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#Sample">¶</a>
				
				
			</h2>
			<pre>func Sample(in chan interface{}, interval <a href="http://localhost:6060/pkg/time/">time</a>.<a href="http://localhost:6060/pkg/time/#Duration">Duration</a>) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="SequenceEqual">func <a href="http://localhost:6060/src/RxGO/operator.go?s=12320:12380#L789">SequenceEqual</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#SequenceEqual">¶</a>
				
				
			</h2>
			<pre>func SequenceEqual(ins ...chan interface{}) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="Skip">func <a href="http://localhost:6060/src/RxGO/operator.go?s=5082:5140#L331">Skip</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#Skip">¶</a>
				
				
			</h2>
			<pre>func Skip(in chan interface{}, count <a href="http://localhost:6060/pkg/builtin/#int">int</a>) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="SkipLast">func <a href="http://localhost:6060/src/RxGO/operator.go?s=5324:5386#L349">SkipLast</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#SkipLast">¶</a>
				
				
			</h2>
			<pre>func SkipLast(in chan interface{}, count <a href="http://localhost:6060/pkg/builtin/#int">int</a>) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="SkipUntil">func <a href="http://localhost:6060/src/RxGO/operator.go?s=13377:13457#L859">SkipUntil</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#SkipUntil">¶</a>
				
				
			</h2>
			<pre>func SkipUntil(in chan interface{}, untilChan chan interface{}) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="SkipWhile">func <a href="http://localhost:6060/src/RxGO/operator.go?s=13742:13811#L886">SkipWhile</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#SkipWhile">¶</a>
				
				
			</h2>
			<pre>func SkipWhile(in chan interface{}, match <a href="http://localhost:6060/pkg/RxGO/#MatchFunc">MatchFunc</a>) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="StartWith">func <a href="http://localhost:6060/src/RxGO/operator.go?s=7021:7094#L458">StartWith</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#StartWith">¶</a>
				
				
			</h2>
			<pre>func StartWith(in chan interface{}, vals ...interface{}) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="Subscribe">func <a href="http://localhost:6060/src/RxGO/operator.go?s=1289:1341#L80">Subscribe</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#Subscribe">¶</a>
				
				
			</h2>
			<pre>func Subscribe(in chan interface{}) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="Sum">func <a href="http://localhost:6060/src/RxGO/operator.go?s=14592:14638#L948">Sum</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#Sum">¶</a>
				
				
			</h2>
			<pre>func Sum(in chan interface{}) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="Switch">func <a href="http://localhost:6060/src/RxGO/operator.go?s=7283:7332#L476">Switch</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#Switch">¶</a>
				
				
			</h2>
			<pre>func Switch(in chan interface{}) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="Take">func <a href="http://localhost:6060/src/RxGO/operator.go?s=5750:5808#L376">Take</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#Take">¶</a>
				
				
			</h2>
			<pre>func Take(in chan interface{}, count <a href="http://localhost:6060/pkg/builtin/#int">int</a>) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="TakeLast">func <a href="http://localhost:6060/src/RxGO/operator.go?s=6016:6078#L397">TakeLast</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#TakeLast">¶</a>
				
				
			</h2>
			<pre>func TakeLast(in chan interface{}, count <a href="http://localhost:6060/pkg/builtin/#int">int</a>) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="TakeUntil">func <a href="http://localhost:6060/src/RxGO/operator.go?s=14041:14121#L907">TakeUntil</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#TakeUntil">¶</a>
				
				
			</h2>
			<pre>func TakeUntil(in chan interface{}, untilChan chan interface{}) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="TakeWhile">func <a href="http://localhost:6060/src/RxGO/operator.go?s=14355:14424#L930">TakeWhile</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#TakeWhile">¶</a>
				
				
			</h2>
			<pre>func TakeWhile(in chan interface{}, match <a href="http://localhost:6060/pkg/RxGO/#MatchFunc">MatchFunc</a>) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="Throw">func <a href="http://localhost:6060/src/RxGO/generator.go?s=2224:2262#L122">Throw</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#Throw">¶</a>
				
				
			</h2>
			<pre>func Throw(err <a href="http://localhost:6060/pkg/builtin/#error">error</a>) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="TimeInterval">func <a href="http://localhost:6060/src/RxGO/operator.go?s=9575:9630#L606">TimeInterval</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#TimeInterval">¶</a>
				
				
			</h2>
			<pre>func TimeInterval(in chan interface{}) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="Timeout">func <a href="http://localhost:6060/src/RxGO/operator.go?s=10064:10137#L639">Timeout</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#Timeout">¶</a>
				
				
			</h2>
			<pre>func Timeout(in chan interface{}, timeout <a href="http://localhost:6060/pkg/time/">time</a>.<a href="http://localhost:6060/pkg/time/#Duration">Duration</a>) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="Timer">func <a href="http://localhost:6060/src/RxGO/generator.go?s=2286:2337#L126">Timer</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#Timer">¶</a>
				
				
			</h2>
			<pre>func Timer(duration <a href="http://localhost:6060/pkg/time/">time</a>.<a href="http://localhost:6060/pkg/time/#Duration">Duration</a>) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="Timestamp">func <a href="http://localhost:6060/src/RxGO/operator.go?s=10459:10511#L666">Timestamp</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#Timestamp">¶</a>
				
				
			</h2>
			<pre>func Timestamp(in chan interface{}) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="Values">func <a href="http://localhost:6060/src/RxGO/generator.go?s=204:250#L10">Values</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#Values">¶</a>
				
				
			</h2>
			<pre>func Values(in chan interface{}) []interface{}</pre>
			
			
			

		
			
			
			<h2 id="WindowWithCount">func <a href="http://localhost:6060/src/RxGO/operator.go?s=17870:17939#L1138">WindowWithCount</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#WindowWithCount">¶</a>
				
				
			</h2>
			<pre>func WindowWithCount(in chan interface{}, count <a href="http://localhost:6060/pkg/builtin/#int">int</a>) chan interface{}</pre>
			
			
			

		
			
			
			<h2 id="Zip">func <a href="http://localhost:6060/src/RxGO/operator.go?s=8130:8182#L520">Zip</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#Zip">¶</a>
				
				
			</h2>
			<pre>func Zip(chans ...chan interface{}) chan interface{}</pre>
			
			
			

		
		
			
			
			<h2 id="FilterFunc">type <a href="http://localhost:6060/src/RxGO/operator.go?s=667:705#L35">FilterFunc</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#FilterFunc">¶</a>
				
				
			</h2>
			
			<pre>type FilterFunc func(interface{}) <a href="http://localhost:6060/pkg/builtin/#bool">bool</a></pre>

			

			

			
			
			

			

			
		
			
			
			<h2 id="GroupByFunc">type <a href="http://localhost:6060/src/RxGO/operator.go?s=2799:2845#L172">GroupByFunc</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#GroupByFunc">¶</a>
				
				
			</h2>
			
			<pre>type GroupByFunc func(interface{}) interface{}</pre>

			

			

			
			
			

			

			
		
			
			
			<h2 id="MapFunc">type <a href="http://localhost:6060/src/RxGO/operator.go?s=74:116#L1">MapFunc</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#MapFunc">¶</a>
				
				
			</h2>
			
			<pre>type MapFunc func(interface{}) interface{}</pre>

			

			

			
			
			

			

			
		
			
			
			<h2 id="MatchFunc">type <a href="http://localhost:6060/src/RxGO/operator.go?s=10685:10722#L681">MatchFunc</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#MatchFunc">¶</a>
				
				
			</h2>
			
			<pre>type MatchFunc func(interface{}) <a href="http://localhost:6060/pkg/builtin/#bool">bool</a></pre>

			

			

			
			
			

			

			
		
			
			
			<h2 id="ReduceFunc">type <a href="http://localhost:6060/src/RxGO/operator.go?s=322:380#L16">ReduceFunc</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#ReduceFunc">¶</a>
				
				
			</h2>
			
			<pre>type ReduceFunc func(interface{}, interface{}) interface{}</pre>

			

			

			
			
			

			

			
		
			
			
			<h2 id="TimeIntervalItem">type <a href="http://localhost:6060/src/RxGO/operator.go?s=9495:9573#L601">TimeIntervalItem</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#TimeIntervalItem">¶</a>
				
				
			</h2>
			
			<pre>type TimeIntervalItem struct {
    <span class="comment">// contains filtered or unexported fields</span>
}
</pre>

			

			

			
			
			

			

			
		
			
			
			<h2 id="TimeoutError">type <a href="http://localhost:6060/src/RxGO/operator.go?s=9957:9985#L632">TimeoutError</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#TimeoutError">¶</a>
				
				
			</h2>
			
			<pre>type TimeoutError struct {
}
</pre>

			

			

			
			
			

			

			
				
				<h3 id="TimeoutError.Error">func (TimeoutError) <a href="http://localhost:6060/src/RxGO/operator.go?s=9987:10034#L635">Error</a>
					<a class="permalink" href="http://localhost:6060/pkg/RxGO/#TimeoutError.Error">¶</a>
					
					
				</h3>
				<pre>func (timeoutError <a href="http://localhost:6060/pkg/RxGO/#TimeoutError">TimeoutError</a>) Error() <a href="http://localhost:6060/pkg/builtin/#string">string</a></pre>
				
				
				
				
			
		
			
			
			<h2 id="TimestampItem">type <a href="http://localhost:6060/src/RxGO/operator.go?s=10384:10457#L661">TimestampItem</a>
				<a class="permalink" href="http://localhost:6060/pkg/RxGO/#TimestampItem">¶</a>
				
				
			</h2>
			
			<pre>type TimestampItem struct {
    <span class="comment">// contains filtered or unexported fields</span>
}
</pre>

			

			

			
			
			

			

			
		
	

	







<div id="footer">
Build version go1.15.3.<br>
Except as <a href="https://developers.google.com/site-policies#restrictions">noted</a>,
the content of this page is licensed under the
Creative Commons Attribution 3.0 License,
and code is licensed under a <a href="http://localhost:6060/LICENSE">BSD license</a>.<br>
<a href="http://localhost:6060/doc/tos.html">Terms of Service</a> |
<a href="http://www.google.com/intl/en/policies/privacy/">Privacy Policy</a>
</div>

</div><!-- .container -->
</div><!-- #page -->


</body></html>